/**
 * @file   ReceivedMessage.java
 * @date   2012-11-7上午10:02:48
 * @author User
 */
package com.gzceb.zhgjj.mina;

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;

/**
 * <p>业务分发入口类。</p>
 *
 * @date   2012-11-7上午10:02:48 
 * @author liqing
 * @description 
 */
public class ReceivedMessage extends IoHandlerAdapter {
	 
	/**
     * 新连接建立的时候触发
     */
    @Override
    public void sessionCreated(IoSession session) throws Exception {
       super.sessionCreated(session);
    }

    /**
     * 新连接打开的时候触发，在sessionCreated之后被调用
     */
    @Override
    public void sessionOpened(IoSession session) throws Exception{
        super.sessionOpened(session);
    }
    /**
     * 连接被关闭的时候触发
     */
    @Override
    public void sessionClosed(IoSession session) throws Exception {
        
        super.sessionClosed(session);
    }
    /**
     * 有消息接收的时候触发
     */
    @Override
    public void messageReceived(IoSession session, Object message)
            throws Exception {
        //获取流数据
        System.out.println("message :"+message);
        session.write("OK");
        
    }
   /**
    * 连接被闲置的时候触发
    */
    @Override
    public void sessionIdle(IoSession session, IdleStatus status)
            throws Exception {
        super.sessionIdle(session, status);
    }
    /**
     * 有异常抛出但是没有被catch的时候触发
     */
    @Override
    public void exceptionCaught(IoSession session,Throwable cause) throws Exception
    {
        super.exceptionCaught(session, cause);
    }
    /**
     * 消息发送的时候触发
     */
    @Override
    public void messageSent(IoSession session, Object message) throws Exception 
    {
        super.messageSent(session, message);
    }
}
